e2dbfe0486bec03a2625cdb9abe237224cf45066,joker-engine/src/test/java/cs/bilkent/joker/engine/tuplequeue/impl/queue/MultiThreadedTupleQueueTest.java,MultiThreadedTupleQueueTest,shouldOfferTupleExceedinglyWithTimeoutWhenCapacityIncreases,#,63
Before Change
public void shouldOfferTupleExceedinglyWithTimeoutWhenCapacityIncreases () throws InterruptedException
{
queue.offerTuple( newTuple( 1 ) );
queue.offerTuple( newTuple( 2 ) );
queue.offerTuple( newTuple( 3 ) );
final Thread thread = spawnThread( increaseCapacity( Thread.currentThread(), 4 ) );
After Change
@Test
public void shouldOfferEmptyTuplesWithTimeout ()
{
final int offered = queue.offerTuples( asList( newTuple( 1 ), newTuple( 2 ) ), 2, TIMEOUT_IN_MILLIS, MILLISECONDS );
assertEquals( 0, offered );
}